package edu.tec.mty.core.modules;

import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
import java.util.HashMap;
import java.util.Vector;

import edu.tec.mty.extras.Pointer;

public class CommunicationManager extends Thread {

	private HashMap<Integer, Module> modules = new HashMap<Integer, Module>();
	private volatile Vector<Pointer<Integer, ModuleMessage>> messagesBuffer = new Vector<Pointer<Integer, ModuleMessage>>();
	
	public void sendMessage(int receiver, ModuleMessage message) {
		this.messagesBuffer.add(new Pointer<Integer, ModuleMessage>(receiver, message));
	}
	
	public void broadcast(ModuleMessage message) {
		
	}
	
	@Override
	public void run() {
		
	}
	
}
